package cn.edu.nchu.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface MySink {
    String MESSAGES_UP = "messages_up";
    String COMMANDS_RESPONSE = "commands_response";
    String PROPERTIES_REPORT = "properties_report";

    @Input(MESSAGES_UP)
    MessageChannel messages_up();

    @Input(COMMANDS_RESPONSE)
    MessageChannel commands_response();

    @Input(PROPERTIES_REPORT)
    MessageChannel properties_report();
}
